package com.ibm.cloud.redismq.mq;

import org.springframework.stereotype.Service;

import com.ibm.cloud.redismq.dto.MessageData;
import com.ibm.cloud.redismq.dto.UserEntity;

import lombok.extern.slf4j.Slf4j;

@Slf4j
@Service
public class EmptyConsumer implements MessageConsumer<UserEntity> {

	@Override
	public void onMessage(MessageData<UserEntity> data) {
		log.info("Consumed data:{}", data);
		try {
			Thread.sleep(100l);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		
	}

}
